#ifndef __threadPool_H__
#define __threadPool_H__
#include <54func.h>
#include "worker.h"
#include "taskQueue.h"
typedef struct threadPool_s{
    // 记录所有的子线程信息
    tidArr_t tidArr;
    // 任务对垒
    taskQueue_t taskQueue;
    // 锁
    pthread_mutex_t mutex;
    // 条件变量
    pthread_cond_t cond;
}threadPool_t;

// 对线程池进行初始化
int threadPoolInit(threadPool_t * pthreadpool,int workerNum);
// 创建子线程
int makeWorker(threadPool_t * pthreadpool,int workerNum);
// 主线程（服务器）进行TCP连接，初始化
int tcpInit(const char *ip,const char *port,int *pockfd);
// 加入监听集合
 int epollAdd(int epfd,int fd);
// 删除监听集合
int epollDel(int epfd,int fd);
// 文件传输
int transFile(int netfd);
#endif
